package com.xes.online.resource;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.SubscribableChannel;

/**
 * @program: scs-demo
 * @description:
 * @author: pkn
 * @create: 2020-06-28 16:18
 */

public interface TalSink {

    @Input("input1")
    SubscribableChannel input1();

    @Input("input2")
    SubscribableChannel input2();

}
